当Rabbit设施出现时，所有bean都可以注解@RabbitListener来创建一个监听器端点。如果没有定义RabbitListenerContainerFactory，Spring Boot将自动配置一个默认的。如果定义MessageConverter beans，它将自动关联到默认的factory。
下面的组件创建一个someQueue队列上的监听器端点：
@Component
public class MyBean {
@RabbitListener(queues = "someQueue")
public void processMessage(String content) {
// ...
}
}
注 具体参考@EnableRabbit。
如果需要创建多个RabbitListenerContainerFactory实例，或想覆盖默认实例，你可以使用Spring Boot提供的SimpleRabbitListenerContainerFactoryConfigurer，通过它可以使用跟自动配置实例相同的配置初始化SimpleRabbitListenerContainerFactory。
例如，下面使用一个特殊的MessageConverter创建了另一个factory：
@Configuration
static class RabbitConfiguration {
@Bean
public SimpleRabbitListenerContainerFactory myFactory(
SimpleRabbitListenerContainerFactoryConfigurer configurer) {
SimpleRabbitListenerContainerFactory factory =
new SimpleRabbitListenerContainerFactory();
configurer.configure(factory, connectionFactory);
factory.setMessageConverter(myMessageConverter());
return factory;
}
}
然后，你可以像下面那样在所有@RabbitListener注解方法中使用：
@Component
public class MyBean {
@RabbitListener(queues = "someQueue", containerFactory="myFactory")
public void processMessage(String content) {
// ...
}
}
你可以启动重试处理那些监听器抛出异常的情况，当重试次数达到限制时，该消息将被拒绝，要不被丢弃，要不路由到一个dead-letter交换器，如果broker这样配置的话，默认禁用重试。
重要 如果没启用重试，且监听器抛出异常，则Rabbit会不定期进行重试。你可以采用两种方式修改该行为：设置defaultRequeueRejected属性为false，这样就不会重试；或抛出一个AmqpRejectAndDontRequeueException异常表示该消息应该被拒绝，这是开启重试，且达到最大重试次数时使用的策略。